package com.atguig.mq.listener;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;

public class FanoutListener2 implements MessageListener {
  
    public void onMessage(Message message) {  
  
        try {  
            String msg = new String(message.getBody(), "utf-8");  
            System.out.printf("广播监听器2：接收路由名称为：%s,路由键为：%s,队列名为：%s的消息：%s \n",
            message.getMessageProperties().getReceivedExchange(),  
            message.getMessageProperties().getReceivedRoutingKey(),  
            message.getMessageProperties().getConsumerQueue(),  
            msg);  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
}